package com.activemq.demo.consumer;

import com.activemq.demo.factory.BeanFactory;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.annotation.JmsListeners;
import org.springframework.stereotype.Service;

/**
 * activeMQ是java开发支持事务的,kafka和rabbitMQ是不支持事务的
 *
 * @author biaoyang
 * @Description:
 * @date 2018/8/30 003015:42
 */
@Service
public class Consumer {

    /**
     * destination类似于kafka的主题(是消费者和生产者共同约定传递某类信息的字符)
     * 监听目的地是consumer的消息(这里没有指明是属于哪种模式)
     *
     * @param msg
     */
    @JmsListener(destination = BeanFactory.JMS_QUEUE)
    public void receiveMsg(String msg) {
        System.err.println("=====队列====="+msg+"=====队列=====");
    }

    /**
     * destination类似于kafka的主题(是消费者和生产者共同约定传递某类信息的字符)
     * 监听目的地是consumer的消息(这里没有指明是属于哪种模式)
     *
     * @param msg
     */
    @JmsListener(destination = BeanFactory.JMS_TOPIC)
    public void receiveMessage(String msg) {
        System.err.println("=====主题====="+msg+"=====主题=====");
    }
}
